package com.netposa.kafka;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;

public class Test {

    public static void main(String[] args) {
        KafkaProducer producer = ProducerFactory.getInstance().getProducer();
        producer.send(new ProducerRecord<String,String>("test","test8"));
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }


    }
}